# from celery import Celery
#
# # 创建一个celery实例对象
# """
# celery三个要素
# １　任务（客户端发送任务）
# ２　 任务队列ｂｒｏｋｅｒ（客户端发送任务到任务队列）
# ３　任务处理者　ｗｏｒｋｅｒ（获取任务队列中的任务）
# 一个ｃｅｌｅｒｙ　可以包含很多个　broker　和 worker
#
# """
# app = Celery("celery_tasks")
#
# # 设置ｂｒｏｋｅｒ使用ｒｅｄｉｓ
# # 填写配置信息的路径
# app.config_from_object('celery_tasks.config')
#
# # 让celery自动检测任务，括号内写任务路径
# app.autodiscover_tasks('celery_tasks.sms')
#
# #我们需要指令让Celery单独执行
# #需要在虚拟环境中执行
# # celery -A celery对象的路径 worker -l info
# # celery -A celery_tasks.main worker -l info

from celery import Celery

# 进行Celery允许配置
# 为celery使用django配置文件进行设置
# 必须在ｃｅｌｅｒｙ实例创建之前
import os

if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'meiduo.settings'

# 创建Celery对象
# 参数main 设置脚本名
app = Celery('celery_tasks')

# 加载配置文件
app.config_from_object('celery_tasks.config')

# 自动加载任务
app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])
